package com.scorpio.mqtt.service;

import org.apache.activemq.command.ActiveMQQueue;

public interface MqttService {

    void pushOrderOverdueQueu(String orderOn,long time);

    /**
     * 定时发送
     * @param queue
     * @param data
     * @param time 毫秒
     */
    void timingGo(ActiveMQQueue queue, String data, long time);
}
